package com.soft863.ct.consumer;

import com.soft863.ct.consumer.bean.CallLogConsumer;
import com.soft863.tc.common.bean.Consumer;

import java.io.IOException;

/*
 * 启动消费者
 * */
public class Bootstrap {
    public static void main(String[] args) throws IOException {
        //创建消费者
        Consumer consumer = new CallLogConsumer();
        //使用kafka的消费者获取flume采集的数据
        consumer.consume();
        //关闭资源
        consumer.close();

    }
}
